package xiaoqi.springboot.boot.listener;

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

public class TestPatternTopicMessageListener implements MessageListener {
    @Override
    public void onMessage(Message message, byte[] pattern) {
        System.out.println("收到 PatternTopic 消息：");
        System.out.println("线程编号: " + Thread.currentThread().getName());
        System.out.println("message: " + message);
        System.out.println("Pattern: " + new String(pattern));
    }
}
